#!/usr/bin/env python
# -*- encoding: utf-8 -*-
'''
@文件 ：async_executor_utils.py
@作者 : mengly
@时间 : 2022/6/20 13:30
@版本 : 1.0
说明  ： 
'''
import asyncio
import pandas as pd

async def read_sql_async(stmt,conn):
    """异步读取sql

    :param stmt:
    :param conn:
    :return:
    """
    loop = asyncio.get_event_loop()
    return await loop.run_in_executor(None,pd.read_sql,stmt,conn)